package com.taobao.txc.a.b;

import com.taobao.txc.common.LoggerWrap;
import java.util.ArrayList;
import java.util.Collection;
import java.util.Iterator;
import java.util.List;
import java.util.concurrent.ConcurrentHashMap;

class q
  implements Runnable
{
  q(p paramp) {}
  
  public void run()
  {
    ArrayList localArrayList = new ArrayList(this.a.n.size());
    Iterator localIterator = this.a.n.values().iterator();
    b localb;
    while (localIterator.hasNext())
    {
      localb = (b)localIterator.next();
      if (localb.a()) {
        localArrayList.add(localb);
      }
    }
    localIterator = localArrayList.iterator();
    while (localIterator.hasNext())
    {
      localb = (b)localIterator.next();
      this.a.n.remove(Long.valueOf(localb.b().e()));
      localb.a(null);
      if (p.m().c()) {
        p.m().debug("timeout clear future : " + localb);
      }
    }
    this.a.i = System.currentTimeMillis();
  }
}


/* Location:           C:\Users\ibm\Downloads\txc-yun-sample (1)\txc-yun-sample\lib\txc-client-2.0.72.jar
 * Qualified Name:     com.taobao.txc.a.b.q
 * JD-Core Version:    0.7.0.1
 */